﻿using Confluent.Kafka;
//using KafkaNet.Protocol;
using System;
using System.Collections.Generic;
using System.Text;

namespace Zhaoxi.KafkaServer
{
	class NetKafka
	{
        public static void Produce(string topicname,string message)
        {
            //var options = new KafkaOptions(new Uri("http://127.0.0.1:9092"));
            //var router = new BrokerRouter(options);
            //var producer = new Producer(router);
            //List<Message> msgArr = new List<Message>();
            //for (int i = 0; i < 100; i++)
            //{
            //    msgArr.Add(new Message(message+":"+i));
            //}
           
            //producer.SendMessageAsync(topicname, msgArr.ToArray()).Wait(3000);

        }
    }
}
